import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

import java.io.IOException;



public class NoAcDegreeMapper extends Mapper<LongWritable, Text, Text, NoAcDegreeFlowBean> {

    NoAcDegreeFlowBean flowBean = new NoAcDegreeFlowBean();
    Text k = new Text();
    @Override
    protected void map(LongWritable key, Text value, Mapper<LongWritable, Text, Text, NoAcDegreeFlowBean>.Context context)
            throws IOException, InterruptedException {
        //分割处理数据
        String[] fields = value.toString().split("\t");

        flowBean.set(fields[3], fields[1], fields[4], Long.parseLong(fields[6]),fields[13]);
        k.set(fields[13]);


        context.write(k, flowBean);

    }

}
